package com.sync.utils.agent.consumer;

import com.sync.utils.agent.pojo.ConsumerDto;
import com.sync.utils.agent.pojo.ServerReq;
import com.sync.utils.agent.pojo.ServerRes;

import java.util.concurrent.TimeoutException;

/**
 * TODO
 *
 * @Author YWF
 * @Date 2025/5/9 15:57
 */
public interface Consumer {
    ConsumerDto communicate(ServerReq<? extends ServerRes> request) throws TimeoutException;
}
